package com.yong.activemq.queue;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class JmsProduce {
    static final String DEFAULT_URL = "tcp://localhost:61616";
    static final String QUEUE_NAME = "queue-01";
    public static void main(String[] args) throws JMSException {
        // 1、创建连接工厂
        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(DEFAULT_URL);

        // 2、通过连接工厂创建connection，并且启动连接
        Connection connection = activeMQConnectionFactory.createConnection();
        connection.start();

        // 3、通过connection创建session
        // 第一个参数：事务； 第二个参数
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 4、通过session创建destination；首先采用queue
        Queue queue = session.createQueue(QUEUE_NAME);

        // 5、通过session创建消息的生产者
        MessageProducer messageProducer = session.createProducer(queue);

        // 6、通过session创建消息内容
        TextMessage textMessage = session.createTextMessage();

        for (int i = 0; i < 4; i++) {
            // 7、设置消息内容
            textMessage.setText("produce msg:"+i);
            // 8、发送消息
            messageProducer.send(textMessage);
        }

        System.out.println("produce 消息成功！");

        // 9、关闭连接
        messageProducer.close();
        session.close();
        connection.close();
    }

}
